package com.suxin.writer;


import com.alibaba.datax.common.plugin.RecordReceiver;
import com.alibaba.datax.common.spi.Writer;
import com.alibaba.datax.common.util.Configuration;

import java.util.List;

/**
 * @Classname MySqlWriter
 * @Description [ MySqlWriter ]
 * @Author Tang
 * @Date 2020/11/14 10:27
 * @Created by ASUS
 */
public class MySqlWriter extends Writer {

    public static class Job extends Writer.Job {

        @Override
        public void init() {
        }

        @Override
        public void prepare() {
        }

        /**
         *adviceNumber 是 读插件的 List<Configuration> split(int adviceNumber)的size
         *
         */
        @Override
        public List<Configuration> split(int adviceNumber) {
            return null;
        }

        @Override
        public void post() {
        }

        @Override
        public void destroy() {
        }

    }

    public static class Task extends Writer.Task {

        @Override
        public void init() {
        }

        @Override
        public void prepare() {
        }

        /**
         * 从 recordReceiver 中读取数据，写入目标源
         * RecordReceiver中的数据来自Reader和Writer之间的缓存队列。
         */

        @Override
        public void startWrite(RecordReceiver recordReceiver) {

        }

        @Override
        public void post() {
        }

        @Override
        public void destroy() {
        }
    }

}